import { NextRequest, NextResponse } from 'next/server';
import { requireAuth } from '@/lib/auth';
import { bsDb } from '@/lib/balancesheet-db';
// GET /api/balancesheet/transactions/[id] - Get a specific transaction
export async function GET(
request: NextRequest,
{ params }: { params: { id: string } }
) {
try {
const user = await requireAuth();
const id = parseInt(params.id);
if (isNaN(id)) {
return NextResponse.json(
{ success: false, error: 'Invalid transaction ID' },
{ status: 400 }
);
}
const transaction = await bsDb.getTransactionById(id, user.id);
if (!transaction) {
return NextResponse.json(
{ success: false, error: 'Transaction not found' },
{ status: 404 }
);
}
return NextResponse.json({ success: true, transaction });
} catch (error: any) {
console.error('Error fetching transaction:', error);
if (error.message === 'Unauthorized') {
return NextResponse.json(
{ success: false, error: 'Unauthorized' },
{ status: 401 }
);
}
return NextResponse.json(
{ success: false, error: error.message },
{ status: 500 }
);
}
}
// PUT /api/balancesheet/transactions/[id] - Update a transaction
export async function PUT(
request: NextRequest,
{ params }: { params: { id: string } }
) {
try {
const user = await requireAuth();
const id = parseInt(params.id);
const body = await request.json();
const { categoryId, bankId, amount, transactionDate, description } = body;
if (isNaN(id)) {
return NextResponse.json(
{ success: false, error: 'Invalid transaction ID' },
{ status: 400 }
);
}
if (!categoryId || !bankId || !amount || !transactionDate) {
return NextResponse.json(
{ success: false, error: 'Category, bank, amount, and date are required' },
{ status: 400 }
);
}
// Verify category and bank belong to user
const category = await bsDb.getCategoryById(categoryId, user.id);
if (!category) {
return NextResponse.json(
{ success: false, error: 'Category not found' },
{ status: 404 }
);
}
const bank = await bsDb.getBankById(bankId, user.id);
if (!bank) {
return NextResponse.json(
{ success: false, error: 'Bank not found' },
{ status: 404 }
);
}
await bsDb.updateTransaction(
id,
user.id,
categoryId,
bankId,
parseFloat(amount),
new Date(transactionDate),
description
);
const transaction = await bsDb.getTransactionById(id, user.id);
return NextResponse.json({ success: true, transaction });
} catch (error: any) {
console.error('Error updating transaction:', error);
if (error.message === 'Unauthorized') {
return NextResponse.json(
{ success: false, error: 'Unauthorized' },
{ status: 401 }
);
}
return NextResponse.json(
{ success: false, error: error.message },
{ status: 500 }
);
}
}
// DELETE /api/balancesheet/transactions/[id] - Delete a transaction
export async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
try {
const user = await requireAuth();
const id = parseInt(params.id);
if (isNaN(id)) {
return NextResponse.json(
{ success: false, error: 'Invalid transaction ID' },
{ status: 400 }
);
}
await bsDb.deleteTransaction(id, user.id);
return NextResponse.json({ success: true });
} catch (error: any) {
console.error('Error deleting transaction:', error);
if (error.message === 'Unauthorized') {
return NextResponse.json(
{ success: false, error: 'Unauthorized' },
{ status: 401 }
);
}
return NextResponse.json(
{ success: false, error: error.message },
{ status: 500 }
);
}
}
